<?php
/**
 * 首页控制器
 */

class IndexController extends BaseController {

	function Index() {

		try {
			$mongo = new Mongo('mongodb://root:@10.245.75.75:65432');
		}
		catch (MongoConnectionException $e) {
			throw_exception('链接不上mongodb服务器');
		}

		$db = $mongo->selectDB('db2_user_0_0');

		$collection = $db->selectCollection('t_user_1');

		$data = array('id'=>11, name=>'王小呆');

//		$res = $collection->insert($data, array('safe'=>''));
//		dump($res);
//
//		$res = $collection->insert($data, array('safe'=>''));
//		dump($res);
//
//		dump($collection->count());

		$cursor = $collection->find(array('id'=>array('$gt'=>2)), array('id','name'));

		while ($cursor->hasNext()) {
			dump($cursor->getNext());
		}

		dump('findOne:');
		$ret = $collection->findOne(array('id'=>array('$gt'=>2)), array('id','name'));
		dump($ret);

//		$data = array('name'=>'王小呆3');
//		$collection->insert($data);
	}

	function Db() {

		$ops = array(
				'cfg'        => DbDispatcher::dispatchTable('user', 20101, 'r'),
			);

//		$data = array();
//		$data['sets'] = array(
//				'id'=>10,
//				'name'=>'王小呆'
//			);
//
//		$mongo_op = MongoOp::getInstance($ops, $data);
//
//		$ret = $mongo_op->insert();
//		dump($ret);

		$data = array();
//		$data['where'] = array(
//				'_id'=>new MongoId('4c1ae8c5577c47b00e030000'),
//			);
//		$data['where'] = array(
//				'id'=>array('$gt'=>7),
//			);
//		$data['sets']  = array(
//				'$inc'=>array(
//					'id'=>1,
//					)
//			);
//
//		$mongo_op = MongoOp::getInstance($ops, $data);
//
//		$ret = $mongo_op->update();
//		dump($ret);


//		$data = array();
//		$data['where'] = array(
//				'id'=>array('$gt'=>7),
//			);
//
//		$mongo_op = MongoOp::getInstance($ops, $data);
//
//		$ret = $mongo_op->delete();
//		dump($ret);

		$data = array();
		$data['where'] = array(
				'id'=>array('$gt'=>2),
			);
		$data['orderby'] = array(
				'id'=>'desc',
			);
		$data['limit'] = array(1,2);

		$mongo_op = MongoOp::getInstance($ops, $data);

//		$ret = $mongo_op->getRow();
//		$ret = $mongo_op->getAssoc();
		$ret = $mongo_op->getCount();
		dump($ret);
	}
}
?>
